package org.cancer.controller

import org.apache.spark.streaming.StreamingContext
import org.apache.spark.streaming.dstream.DStream
import org.cancer.bean.CancersData
import org.cancer.service.CancersHighAreaService$Laurel

class CancersHighAreaController {
  val cancersHighAreaService = new CancersHighAreaService$Laurel()

  def dispatch(data:DStream[CancersData])(implicit ssc: StreamingContext):Unit ={

    cancersHighAreaService.realtimeCancersAnalysis(data)
  }

}
